package com.hyt.it.ogt.ks.config.canal;

import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.stereotype.Component;

import lombok.Getter;


/**
 * <p>
 *  canal配置信息
 * </p>
 *
 * @author zhoumiao
 * @since 2022-11-09
 */

@Getter
@Component
@RefreshScope
public class CanalConfig {


    @Value("${canal.canalip}")
    private String canalip;
    
    @Value("${canal.canalport}")
    private Integer canalport;

    @Value("${canal.database}")
    private String database;

    @Value("${canal.canaldestination}")
    private String canaldestination;

    @Value("${canal.isEnable:true}")
    private Boolean isEnable;

    @Value("${canal.sleepSeconds:3}")
    private Long sleepSeconds;

    @Value("${canal.batchSize:1000}")
    private int batchSize;

}
